-
Couldn't load subscription status.
- Fork 51
return work from manager allreduce #247
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Summary: use http transport instead of pg transport -- pg transport fails to resolve address when running locally
48daf18 to
e6715b0
Compare
843854d to
1bfb3d8
Compare
e83bf1e to
0973ddc
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
| fut = fut.then(callback) | ||
| return fut | ||
| fut.add_done_callback(callback) | ||
| return work |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should this be using _WorkWrapper ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
that's returned by manager. the manager calls this method inside allreduce
411ae90 to
fd371a7
Compare
Summary: - call future.wait in callbacks to make sure the continuation executes after the future has completed - set the stream correctly to execute callback scheduled by bucketized allreduce
Summary: returns the work object so we can be more flexible with the usage
Summary:
returns the work object so we can be more flexible with the usage
Stack created with Sapling. Best reviewed with ReviewStack.